package cn.tedu.batch.source

import org.apache.flink.api.scala.ExecutionEnvironment

/**
 * @author Amos
 * @date 2022/5/19
 */

object FromCollectionSource {
  def main(args: Array[String]): Unit = {
    val env: ExecutionEnvironment = ExecutionEnvironment.getExecutionEnvironment

    import org.apache.flink.api.scala._
    val source1:DataSet[String] = env.fromElements("flink", "hadoop")
    source1.print()
  }

}
